package mr.weblog.support;

import static org.apache.hadoop.hbase.util.Bytes.*;


/**
Statement to create schema:

  create 'EnhancedLogs', {NAME=>'joined',COMPRESSION=>'GZ'}
 
 */
public interface WeblogHBaseSchema {
    public static String ENHANCED_LOGS_TABLE = "EnhancedLogs";

    public static byte[] ENHANCED_LOGS_FAMILY_CONTENT = toBytes("joined");
    
    public static byte[] WEBLOG_CLIENT_IP_COL = toBytes("client_ip");
    public static byte[] WEBLOG_USER_ID_COL = toBytes("user_id");
    public static byte[] WEBLOG_TIMESTAMP_COL = toBytes("timestamp");
    public static byte[] WEBLOG_STOCK_URL_COL = toBytes("url_with_stock");
    public static byte[] WEBLOG_STOCK_SYMBOL_COL = toBytes("stock_symbol");
    
    public static byte[] WEBLOG_LOG_COL= toBytes("log");
    public static byte[] WEBLOG_PRICE_TIMESTAMP_COL = toBytes("price_timestamp");
    public static byte[] WEBLOG_PRICE_COL = toBytes("price");

    //error table
    public static String ERROR_TABLE = "ErrorTable";
    public static byte[] ERROR_FAMILY =  toBytes("errors");
    public static byte[] ERROR_COLUMN_EXCEPTION =  toBytes("exception");
}
